package com.joven.internet.constant;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author joven_wong
 * 2021/6/10 17:05
 * sink
 */
public interface JovenInput {
    String INPUT = "input";
    String DLQ_INPUT = "inputDlq";

    @Input(INPUT)
    SubscribableChannel input();

    @Input(DLQ_INPUT)
    SubscribableChannel inputDlq();
}
